f4e1065b6d270f67009fadf78f709a422cbd3b9d,metron-platform/metron-management/src/test/java/org/apache/metron/management/KafkaFunctionsIntegrationTest.java,KafkaFunctionsIntegrationTest,setupKafka,#,59
Before Change
Properties properties = new Properties();
kafkaComponent = getKafkaComponent(properties, new ArrayList<>());
runner = new ComponentRunner.Builder()
.withComponent("kafka", kafkaComponent)
.withMillisecondsBetweenAttempts(5000)
.withNumRetries(5)
.build();
runner.start();
}
After Change
public static void setupKafka() throws Exception {
Properties properties = new Properties();
zkServerComponent = getZKServerComponent(properties);
kafkaComponent = getKafkaComponent(properties, new ArrayList<>());
runner = new ComponentRunner.Builder()
.withComponent("zk", zkServerComponent)
.withComponent("kafka", kafkaComponent)
.withMillisecondsBetweenAttempts(5000)
.withNumRetries(5)
.withCustomShutdownOrder(new String[]{"kafka","zk"})
.build();
runner.start();
}